const mysql = require('mysql')

let connection = null;

// 创建数据池
const pool = mysql.createPool({
    host: '127.0.0.1',   // 数据库地址
    user: 'root',    // 数据库用户
    password: '123456',   // 数据库密码
    database: 'zhima'  // 选中数据库
})

function execQuery(sql) {
    // getConn().connect()
    // console.log("sql=", sql);

    return new Promise(
        (resolve, reject) => {
            // 执行sql脚本对数据库进行读写 
            // getConn().query(
            //     sql,
            //     (error, results, fields) => {
            //         error ? reject(error) : resolve(results)
            //     }
            // )

            // 在数据池中进行会话操作
            pool.getConnection(function (err, connection) {
                connection.query(
                    sql,
                    (error, results, fields) => {
                        // console.log("results=", results);

                        // 结束会话
                        connection.release();
                        error ? reject(error) : resolve(results)
                    })
            })
        }
    )
}

function getQuestionOptions(qid) {
    getConn().query(
        sql,
        (error, results, fields) => {
            error ? reject(error) : resolve(results)
        }
    )
}

module.exports = {
    execQuery
}